SparkN0de-git - /page/blob.mu

Tff7b72import T7ee787os

Tff7b72import T7ee787sys

Tff7b72import T7ee787time

Tff7b72import T7ee787math

Tff7b72import T7ee787random

Tff7b72import T7ee787base64

Tff7b72import T7ee787atexit

Tff7b72import T7ee787signal

Tff7b72import T7ee787threading

Tff7b72from T7ee787collections Tff7b72import Te6edf3deque

Tff7b72import T7ee787RNS

Tff7b72import T7ee787RNST7ee787.T7ee787vendorT7ee787.T7ee787umsgpack Tff7b72as T7ee787msgpack

Tff7b72from T7ee787.T7ee787LXMF Tff7b72import Te6edf3APP_NAME

Tff7b72from T7ee787.T7ee787LXMF Tff7b72import Te6edf3FIELD_TICKET

Tff7b72from T7ee787.T7ee787LXMF Tff7b72import Te6edf3PN_META_NAME

Tff7b72from T7ee787.T7ee787LXMF Tff7b72import Te6edf3pn_announce_data_is_valid

Tff7b72from T7ee787.T7ee787LXMPeer Tff7b72import Te6edf3LXMPeer

Tff7b72from T7ee787.T7ee787LXMessage Tff7b72import Te6edf3LXMessage

Tff7b72from T7ee787.T7ee787Handlers Tff7b72import Te6edf3LXMFDeliveryAnnounceHandler

Tff7b72from T7ee787.T7ee787Handlers Tff7b72import Te6edf3LXMFPropagationAnnounceHandler

Tff7b72import T7ee787LXMFT7ee787.T7ee787LXStamper Tff7b72as T7ee787LXStamper

Tff7b72class T56d364LXMRouterTb4b4b4:

Te6edf3MAX_DELIVERY_ATTEMPTS Tff7b72= T79c0ff5

Te6edf3PROCESSING_INTERVAL Tff7b72= T79c0ff4

Te6edf3DELIVERY_RETRY_WAIT Tff7b72= T79c0ff10

Te6edf3PATH_REQUEST_WAIT Tff7b72= T79c0ff7

Te6edf3MAX_PATHLESS_TRIES Tff7b72= T79c0ff1

Te6edf3LINK_MAX_INACTIVITY Tff7b72= T79c0ff10Tff7b72*T79c0ff60

Te6edf3P_LINK_MAX_INACTIVITY Tff7b72= T79c0ff3Tff7b72*T79c0ff60

Te6edf3MESSAGE_EXPIRY Tff7b72= T79c0ff30Tff7b72*T79c0ff24Tff7b72*T79c0ff60Tff7b72*T79c0ff60

Te6edf3STAMP_COST_EXPIRY Tff7b72= T79c0ff45Tff7b72*T79c0ff24Tff7b72*T79c0ff60Tff7b72*T79c0ff60

Te6edf3NODE_ANNOUNCE_DELAY Tff7b72= T79c0ff20

Te6edf3MAX_PEERS Tff7b72= T79c0ff20

Te6edf3AUTOPEER Tff7b72= Tff7b72True

Te6edf3AUTOPEER_MAXDEPTH Tff7b72= T79c0ff4

Te6edf3FASTEST_N_RANDOM_POOL Tff7b72= T79c0ff2

Te6edf3ROTATION_HEADROOM_PCT Tff7b72= T79c0ff10

Te6edf3ROTATION_AR_MAX Tff7b72= T79c0ff0.5

Te6edf3PEERING_COST Tff7b72= T79c0ff18

Te6edf3MAX_PEERING_COST Tff7b72= T79c0ff26

Te6edf3PROPAGATION_COST_MIN Tff7b72= T79c0ff13

Te6edf3PROPAGATION_COST_FLEX Tff7b72= T79c0ff3

Te6edf3PROPAGATION_COST Tff7b72= T79c0ff16

Te6edf3PROPAGATION_LIMIT Tff7b72= T79c0ff256

Te6edf3SYNC_LIMIT Tff7b72= Te6edf3PROPAGATION_LIMITTff7b72*T79c0ff40

Te6edf3DELIVERY_LIMIT Tff7b72= T79c0ff1000

Te6edf3PR_PATH_TIMEOUT Tff7b72= T79c0ff10

Te6edf3PN_STAMP_THROTTLE Tff7b72= T79c0ff180

Te6edf3PR_IDLE Tff7b72= T79c0ff0x00

Te6edf3PR_PATH_REQUESTED Tff7b72= T79c0ff0x01

Te6edf3PR_LINK_ESTABLISHING Tff7b72= T79c0ff0x02

Te6edf3PR_LINK_ESTABLISHED Tff7b72= T79c0ff0x03

Te6edf3PR_REQUEST_SENT Tff7b72= T79c0ff0x04

Te6edf3PR_RECEIVING Tff7b72= T79c0ff0x05

Te6edf3PR_RESPONSE_RECEIVED Tff7b72= T79c0ff0x06

Te6edf3PR_COMPLETE Tff7b72= T79c0ff0x07

Te6edf3PR_NO_PATH Tff7b72= T79c0ff0xf0

Te6edf3PR_LINK_FAILED Tff7b72= T79c0ff0xf1

Te6edf3PR_TRANSFER_FAILED Tff7b72= T79c0ff0xf2

Te6edf3PR_NO_IDENTITY_RCVD Tff7b72= T79c0ff0xf3

Te6edf3PR_NO_ACCESS Tff7b72= T79c0ff0xf4

Te6edf3PR_FAILED Tff7b72= T79c0ff0xfe

Te6edf3PR_ALL_MESSAGES Tff7b72= T79c0ff0x00

Te6edf3DUPLICATE_SIGNAL Tff7b72= Ta5d6ff"Ta5d6fflxmf_duplicateTa5d6ff"

Te6edf3STATS_GET_PATH Tff7b72= Ta5d6ff"Ta5d6ff/pn/get/statsTa5d6ff"

Te6edf3SYNC_REQUEST_PATH Tff7b72= Ta5d6ff"Ta5d6ff/pn/peer/syncTa5d6ff"

Te6edf3UNPEER_REQUEST_PATH Tff7b72= Ta5d6ff"Ta5d6ff/pn/peer/unpeerTa5d6ff"

T8b949e### Developer-facing API ##############################

T8b949e#######################################################

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identityTff7b72=Tff7b72NoneTb4b4b4, Te6edf3storagepathTff7b72=Tff7b72NoneTb4b4b4, Te6edf3autopeerTff7b72=Te6edf3AUTOPEERTb4b4b4, Te6edf3autopeer_maxdepthTff7b72=Tff7b72NoneTb4b4b4,

Te6edf3propagation_limitTff7b72=Te6edf3PROPAGATION_LIMITTb4b4b4, Te6edf3delivery_limitTff7b72=Te6edf3DELIVERY_LIMITTb4b4b4, Te6edf3sync_limitTff7b72=Te6edf3SYNC_LIMITTb4b4b4,

Te6edf3enforce_ratchetsTff7b72=Tff7b72FalseTb4b4b4, Te6edf3enforce_stampsTff7b72=Tff7b72FalseTb4b4b4, Te6edf3static_peers Tff7b72= Tb4b4b4[Tb4b4b4]Tb4b4b4, Te6edf3max_peersTff7b72=Tff7b72NoneTb4b4b4,

Te6edf3from_static_onlyTff7b72=Tff7b72FalseTb4b4b4, Te6edf3sync_strategyTff7b72=Te6edf3LXMPeerTff7b72.Td2a8ffSTRATEGY_PERSISTENTTb4b4b4,

Te6edf3propagation_costTff7b72=Te6edf3PROPAGATION_COSTTb4b4b4, Te6edf3propagation_cost_flexibilityTff7b72=Te6edf3PROPAGATION_COST_FLEXTb4b4b4,

Te6edf3peering_costTff7b72=Te6edf3PEERING_COSTTb4b4b4, Te6edf3max_peering_costTff7b72=Te6edf3MAX_PEERING_COSTTb4b4b4, Te6edf3nameTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Te6edf3randomTff7b72.Td2a8ffseedTb4b4b4(Te6edf3osTff7b72.Td2a8ffurandomTb4b4b4(T79c0ff10Tb4b4b4)Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpending_inbound Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffpending_outbound Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8fffailed_outbound Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffdirect_links Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffbackchannel_links Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffdelivery_destinations Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffprioritised_list Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffignored_list Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffallowed_list Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_list Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffauth_required Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffretain_synced_on_node Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffdefault_sync_strategy Tff7b72= Te6edf3sync_strategy

Tff7b72selfTff7b72.Td2a8ffprocessing_outbound Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffprocessing_inbound Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffname Tff7b72= Te6edf3name

Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffpropagation_node_start_time Tff7b72= Tff7b72None

Tff7b72if Te6edf3storagepath Tff7b72== Tff7b72NoneTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffLXMF cannot be initialised without a storage pathTa5d6ff"Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffstoragepath Tff7b72= Te6edf3storagepathTff7b72+Ta5d6ff"Ta5d6ff/lxmfTa5d6ff"

Tff7b72selfTff7b72.Td2a8ffratchetpath Tff7b72= Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/ratchetsTa5d6ff"

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_node Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72= Tff7b72None

Tff7b72if Te6edf3delivery_limit Tff7b72== Tff7b72NoneTb4b4b4: Te6edf3delivery_limit Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffDELIVERY_LIMIT

Tff7b72if Te6edf3propagation_cost Tff7b72< Te6edf3LXMRouterTff7b72.Td2a8ffPROPAGATION_COST_MINTb4b4b4: Te6edf3propagation_cost Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPROPAGATION_COST_MIN

Tff7b72selfTff7b72.Td2a8ffmessage_storage_limit Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffinformation_storage_limit Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffpropagation_per_transfer_limit Tff7b72= Te6edf3propagation_limit

Tff7b72selfTff7b72.Td2a8ffpropagation_per_sync_limit Tff7b72= Te6edf3sync_limit

Tff7b72selfTff7b72.Td2a8ffdelivery_per_transfer_limit Tff7b72= Te6edf3delivery_limit

Tff7b72selfTff7b72.Td2a8ffpropagation_stamp_cost Tff7b72= Te6edf3propagation_cost

Tff7b72selfTff7b72.Td2a8ffpropagation_stamp_cost_flexibility Tff7b72= Te6edf3propagation_cost_flexibility

Tff7b72selfTff7b72.Td2a8ffpeering_cost Tff7b72= Te6edf3peering_cost

Tff7b72selfTff7b72.Td2a8ffmax_peering_cost Tff7b72= Te6edf3max_peering_cost

Tff7b72selfTff7b72.Td2a8ffenforce_ratchets Tff7b72= Te6edf3enforce_ratchets

Tff7b72selfTff7b72.Td2a8ff_enforce_stamps Tff7b72= Te6edf3enforce_stamps

Tff7b72selfTff7b72.Td2a8ffpending_deferred_stamps Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffthrottled_peers Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72if Te6edf3sync_limit Tff7b72== Tff7b72None Tff7b72or Tff7b72selfTff7b72.Td2a8ffpropagation_per_sync_limit Tff7b72< Tff7b72selfTff7b72.Td2a8ffpropagation_per_transfer_limitTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffpropagation_per_sync_limit Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_per_transfer_limit

Tff7b72selfTff7b72.Td2a8ffwants_download_on_path_available_from Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffwants_download_on_path_available_to Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_IDLE

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_progress Tff7b72= T79c0ff0.0

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_last_result Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_last_duplicates Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_max_messages Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffprioritise_rotating_unreachable_peers Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffactive_propagation_links Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffvalidated_peer_links Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costs Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffavailable_tickets Tff7b72= Tb4b4b4{Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4: Tb4b4b4{Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4: Tb4b4b4{Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6fflast_deliveriesTa5d6ff"Tb4b4b4: Tb4b4b4{Tb4b4b4}Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffcost_file_lock Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffticket_file_lock Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffstamp_gen_lock Tff7b72= Te6edf3threadingTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffexit_handler_running Tff7b72= Tff7b72False

Tff7b72if Te6edf3identity Tff7b72== Tff7b72NoneTb4b4b4:

Te6edf3identity Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffidentity Tff7b72= Te6edf3identity

Tff7b72selfTff7b72.Td2a8ffpropagation_destination Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTb4b4b4(Tff7b72selfTff7b72.Td2a8ffidentityTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffINTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffSINGLETb4b4b4, Te6edf3APP_NAMETb4b4b4, Ta5d6ff"Ta5d6ffpropagationTa5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffset_default_app_dataTb4b4b4(Tff7b72selfTff7b72.Td2a8ffget_propagation_node_app_dataTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffcontrol_destination Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_received Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_served Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_incoming Tff7b72= T79c0ff0

Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_rx_bytes Tff7b72= T79c0ff0

Tff7b72if Te6edf3autopeer Tff7b72!= Tff7b72NoneTb4b4b4: Tff7b72selfTff7b72.Td2a8ffautopeer Tff7b72= Te6edf3autopeer

Tff7b72elseTb4b4b4: Tff7b72selfTff7b72.Td2a8ffautopeer Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffAUTOPEER

Tff7b72if Te6edf3autopeer_maxdepth Tff7b72!= Tff7b72NoneTb4b4b4: Tff7b72selfTff7b72.Td2a8ffautopeer_maxdepth Tff7b72= Te6edf3autopeer_maxdepth

Tff7b72elseTb4b4b4: Tff7b72selfTff7b72.Td2a8ffautopeer_maxdepth Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffAUTOPEER_MAXDEPTH

Tff7b72if Te6edf3max_peers Tff7b72== Tff7b72NoneTb4b4b4: Tff7b72selfTff7b72.Td2a8ffmax_peers Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffMAX_PEERS

Tff7b72elseTb4b4b4:

Tff7b72if Tffa657typeTb4b4b4(Te6edf3max_peersTb4b4b4) Tff7b72== Tffa657int Tff7b72and Te6edf3max_peers Tff7b72>Tff7b72= T79c0ff0Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmax_peers Tff7b72= Te6edf3max_peers

Tff7b72elseTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffInvalid value for max_peers: Tffd700{Te6edf3max_peersTffd700}Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8fffrom_static_only Tff7b72= Te6edf3from_static_only

Tff7b72if Tffa657typeTb4b4b4(Te6edf3static_peersTb4b4b4) Tff7b72!= Tffa657listTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffInvalid type supplied for static peer list: Tffd700{Tffa657typeTb4b4b4(Te6edf3static_peersTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72for Te6edf3static_peer Tff7b72in Te6edf3static_peersTb4b4b4:

Tff7b72if Tffa657typeTb4b4b4(Te6edf3static_peerTb4b4b4) Tff7b72!= Tffa657bytesTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffInvalid static peer destination hash: Tffd700{Te6edf3static_peerTffd700}Ta5d6ff"Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Te6edf3static_peerTb4b4b4) Tff7b72!= Te6edf3RNSTff7b72.Td2a8ffReticulumTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffInvalid static peer destination hash: Tffd700{Te6edf3static_peerTffd700}Ta5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffstatic_peers Tff7b72= Te6edf3static_peers

Tff7b72selfTff7b72.Td2a8ffpeers Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffpropagation_entries Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffpeer_distribution_queue Tff7b72= Te6edf3dequeTb4b4b4(Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffregister_announce_handlerTb4b4b4(Te6edf3LXMFDeliveryAnnounceHandlerTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffregister_announce_handlerTb4b4b4(Te6edf3LXMFPropagationAnnounceHandlerTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff__delivery_callback Tff7b72= Tff7b72None

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/local_deliveriesTa5d6ff"Tb4b4b4)Tb4b4b4:

Te6edf3locally_delivered_file Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/local_deliveriesTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4)

Te6edf3data Tff7b72= Te6edf3locally_delivered_fileTff7b72.Td2a8ffreadTb4b4b4(Tb4b4b4)

Te6edf3locally_delivered_fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_ids Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72if Tff7b72not Tffa657typeTb4b4b4(Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_idsTb4b4b4) Tff7b72== Tffa657dictTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffInvalid data format for loaded locally delivered transient IDs, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not load locally delivered message ID cache from storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/locally_processedTa5d6ff"Tb4b4b4)Tb4b4b4:

Te6edf3locally_processed_file Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/locally_processedTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4)

Te6edf3data Tff7b72= Te6edf3locally_processed_fileTff7b72.Td2a8ffreadTb4b4b4(Tb4b4b4)

Te6edf3locally_processed_fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_ids Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72if Tff7b72not Tffa657typeTb4b4b4(Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_idsTb4b4b4) Tff7b72== Tffa657dictTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffInvalid data format for loaded locally processed transient IDs, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not load locally processed message ID cache from storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72tryTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffclean_transient_id_cachesTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not clean transient ID caches. The contained exception was : Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_ids Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/outbound_stamp_costsTa5d6ff"Tb4b4b4)Tb4b4b4:

Tff7b72with Tff7b72selfTff7b72.Td2a8ffcost_file_lockTb4b4b4:

Tff7b72with Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/outbound_stamp_costsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3outbound_stamp_cost_fileTb4b4b4:

Te6edf3data Tff7b72= Te6edf3outbound_stamp_cost_fileTff7b72.Td2a8ffreadTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costs Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72if Tff7b72not Tffa657typeTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4) Tff7b72== Tffa657dictTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffInvalid data format for loaded outbound stamp costs, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costs Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffclean_outbound_stamp_costsTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffsave_outbound_stamp_costsTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not load outbound stamp costs from storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/available_ticketsTa5d6ff"Tb4b4b4)Tb4b4b4:

Tff7b72with Tff7b72selfTff7b72.Td2a8ffticket_file_lockTb4b4b4:

Tff7b72with Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/available_ticketsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3available_tickets_fileTb4b4b4:

Te6edf3data Tff7b72= Te6edf3available_tickets_fileTff7b72.Td2a8ffreadTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_tickets Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72if Tff7b72not Tffa657typeTb4b4b4(Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4) Tff7b72== Tffa657dictTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffInvalid data format for loaded available tickets, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_tickets Tff7b72= Tb4b4b4{Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4: Tb4b4b4{Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4: Tb4b4b4{Tb4b4b4}Tb4b4b4, Ta5d6ff"Ta5d6fflast_deliveriesTa5d6ff"Tb4b4b4: Tb4b4b4{Tb4b4b4}Tb4b4b4}

Tff7b72if Tff7b72not Ta5d6ff"Ta5d6ffoutboundTa5d6ff" Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffMissing outbound entry in loaded available tickets, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72if Tff7b72not Ta5d6ff"Ta5d6ffinboundTa5d6ff" Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffMissing inbound entry in loaded available tickets, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72if Tff7b72not Ta5d6ff"Ta5d6fflast_deliveriesTa5d6ff" Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffMissing local_deliveries entry in loaded available tickets, recreating...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6fflast_deliveriesTa5d6ff"Tb4b4b4] Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72selfTff7b72.Td2a8ffclean_available_ticketsTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffsave_available_ticketsTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not load outbound stamp costs from storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3atexitTff7b72.Td2a8ffregisterTb4b4b4(Tff7b72selfTff7b72.Td2a8ffexit_handlerTb4b4b4)

Te6edf3signalTff7b72.Td2a8ffsignalTb4b4b4(Te6edf3signalTff7b72.Td2a8ffSIGINTTb4b4b4, Tff7b72selfTff7b72.Td2a8ffsigint_handlerTb4b4b4)

Te6edf3signalTff7b72.Td2a8ffsignalTb4b4b4(Te6edf3signalTff7b72.Td2a8ffSIGTERMTb4b4b4, Tff7b72selfTff7b72.Td2a8ffsigterm_handlerTb4b4b4)

Te6edf3job_thread Tff7b72= Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ffjobloopTb4b4b4)

Te6edf3job_threadTff7b72.Td2a8ffsetDaemonTb4b4b4(Tff7b72TrueTb4b4b4)

Te6edf3job_threadTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffannounceTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4, Te6edf3attached_interfaceTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4[Te6edf3destination_hashTb4b4b4]Tff7b72.Td2a8ffannounceTb4b4b4(Te6edf3app_dataTff7b72=Tff7b72selfTff7b72.Td2a8ffget_announce_app_dataTb4b4b4(Te6edf3destination_hashTb4b4b4)Tb4b4b4, Te6edf3attached_interfaceTff7b72=Te6edf3attached_interfaceTb4b4b4)

Tff7b72def Td2a8ffget_propagation_node_announce_metadataTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3metadata Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72if Tff7b72selfTff7b72.Td2a8ffnameTb4b4b4: Te6edf3metadataTb4b4b4[Te6edf3PN_META_NAMETb4b4b4] Tff7b72= Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffnameTb4b4b4)Tff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Tff7b72return Te6edf3metadata

Tff7b72def Td2a8ffget_propagation_node_app_dataTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3metadata Tff7b72= Tff7b72selfTff7b72.Td2a8ffget_propagation_node_announce_metadataTb4b4b4(Tb4b4b4)

Te6edf3node_state Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72and Tff7b72not Tff7b72selfTff7b72.Td2a8fffrom_static_only

Te6edf3stamp_cost Tff7b72= Tb4b4b4[Tff7b72selfTff7b72.Td2a8ffpropagation_stamp_costTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpropagation_stamp_cost_flexibilityTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpeering_costTb4b4b4]

Te6edf3announce_data Tff7b72= Tb4b4b4[ Tff7b72FalseTb4b4b4, T8b949e# 0: Legacy LXMF PN support

Tffa657intTb4b4b4(Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4, T8b949e# 1: Current node timebase

Te6edf3node_stateTb4b4b4, T8b949e# 2: Boolean flag signalling propagation node state

Tff7b72selfTff7b72.Td2a8ffpropagation_per_transfer_limitTb4b4b4, T8b949e# 3: Per-transfer limit for message propagation in kilobytes

Tff7b72selfTff7b72.Td2a8ffpropagation_per_sync_limitTb4b4b4, T8b949e# 4: Limit for incoming propagation node syncs

Te6edf3stamp_costTb4b4b4, T8b949e# 5: Propagation stamp cost for this node

Te6edf3metadata Tb4b4b4] T8b949e# 6: Node metadata

Tff7b72return Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Te6edf3announce_dataTb4b4b4)

Tff7b72def Td2a8ffannounce_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72def Td2a8ffdelayed_announceTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(Te6edf3LXMRouterTff7b72.Td2a8ffNODE_ANNOUNCE_DELAYTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffannounceTb4b4b4(Te6edf3app_dataTff7b72=Tff7b72selfTff7b72.Td2a8ffget_propagation_node_app_dataTb4b4b4(Tb4b4b4)Tb4b4b4)

Te6edf3da_thread Tff7b72= Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Te6edf3delayed_announceTb4b4b4)

Te6edf3da_threadTff7b72.Td2a8ffsetDaemonTb4b4b4(Tff7b72TrueTb4b4b4)

Te6edf3da_threadTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffregister_delivery_identityTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identityTb4b4b4, Te6edf3display_name Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3stamp_cost Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4) Tff7b72!= T79c0ff0Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCurrently only one delivery identity is supported per LXMF router instanceTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72return Tff7b72None

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffratchetpathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffratchetpathTb4b4b4)

Te6edf3delivery_destination Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTb4b4b4(Te6edf3identityTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffINTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffSINGLETb4b4b4, Te6edf3APP_NAMETb4b4b4, Ta5d6ff"Ta5d6ffdeliveryTa5d6ff"Tb4b4b4)

Te6edf3delivery_destinationTff7b72.Td2a8ffenable_ratchetsTb4b4b4(Ta5d6fffTa5d6ff"Tffd700{Tff7b72selfTff7b72.Td2a8ffratchetpathTffd700}Ta5d6ff/Tffd700{Te6edf3RNSTff7b72.Td2a8ffhexrepTb4b4b4(Te6edf3delivery_destinationTff7b72.Td2a8ffhashTb4b4b4, Te6edf3delimitTff7b72=Tff7b72FalseTb4b4b4)Tffd700}Ta5d6ff.ratchetsTa5d6ff"Tb4b4b4)

Te6edf3delivery_destinationTff7b72.Td2a8ffset_packet_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffdelivery_packetTb4b4b4)

Te6edf3delivery_destinationTff7b72.Td2a8ffset_link_established_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffdelivery_link_establishedTb4b4b4)

Te6edf3delivery_destinationTff7b72.Td2a8ffdisplay_name Tff7b72= Te6edf3display_name

Tff7b72if Tff7b72selfTff7b72.Td2a8ffenforce_ratchetsTb4b4b4:

Te6edf3delivery_destinationTff7b72.Td2a8ffenforce_ratchetsTb4b4b4(Tb4b4b4)

Tff7b72if Te6edf3display_name Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72def Td2a8ffget_app_dataTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffget_announce_app_dataTb4b4b4(Te6edf3delivery_destinationTff7b72.Td2a8ffhashTb4b4b4)

Te6edf3delivery_destinationTff7b72.Td2a8ffset_default_app_dataTb4b4b4(Te6edf3get_app_dataTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4[Te6edf3delivery_destinationTff7b72.Td2a8ffhashTb4b4b4] Tff7b72= Te6edf3delivery_destination

Tff7b72selfTff7b72.Td2a8ffset_inbound_stamp_costTb4b4b4(Te6edf3delivery_destinationTff7b72.Td2a8ffhashTb4b4b4, Te6edf3stamp_costTb4b4b4)

Tff7b72return Te6edf3delivery_destination

Tff7b72def Td2a8ffregister_delivery_callbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff__delivery_callback Tff7b72= Te6edf3callback

Tff7b72def Td2a8ffset_inbound_stamp_costTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4, Te6edf3stamp_costTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4:

Te6edf3delivery_destination Tff7b72= Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4[Te6edf3destination_hashTb4b4b4]

Tff7b72if Te6edf3stamp_cost Tff7b72== Tff7b72NoneTb4b4b4:

Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost Tff7b72= Tff7b72None

Tff7b72return Tff7b72True

Tff7b72elif Tffa657typeTb4b4b4(Te6edf3stamp_costTb4b4b4) Tff7b72== Tffa657intTb4b4b4:

Tff7b72if Te6edf3stamp_cost Tff7b72< T79c0ff1Tb4b4b4:

Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost Tff7b72= Tff7b72None

Tff7b72elif Te6edf3stamp_cost Tff7b72< T79c0ff255Tb4b4b4:

Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost Tff7b72= Te6edf3stamp_cost

Tff7b72elseTb4b4b4:

Tff7b72return Tff7b72False

Tff7b72return Tff7b72True

Tff7b72return Tff7b72False

Tff7b72def Td2a8ffget_outbound_stamp_costTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4:

Te6edf3stamp_cost Tff7b72= Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4[T79c0ff1Tb4b4b4]

Tff7b72return Te6edf3stamp_cost

Tff7b72elseTb4b4b4:

Tff7b72return Tff7b72None

Tff7b72def Td2a8ffset_active_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffset_outbound_propagation_nodeTb4b4b4(Te6edf3destination_hashTb4b4b4)

T8b949e# self.set_inbound_propagation_node(destination_hash)

Tff7b72def Td2a8ffset_outbound_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Te6edf3destination_hashTb4b4b4) Tff7b72!= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8 Tff7b72or Tffa657typeTb4b4b4(Te6edf3destination_hashTb4b4b4) Tff7b72!= Tffa657bytesTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffInvalid destination hash for outbound propagation nodeTa5d6ff"Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_node Tff7b72!= Te6edf3destination_hashTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_node Tff7b72= Te6edf3destination_hash

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffdestinationTff7b72.Td2a8ffhash Tff7b72!= Te6edf3destination_hashTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72= Tff7b72None

Tff7b72def Td2a8ffget_outbound_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_node

Tff7b72def Td2a8ffget_outbound_propagation_costTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3target_propagation_cost Tff7b72= Tff7b72None

Te6edf3pn_destination_hash Tff7b72= Tff7b72selfTff7b72.Td2a8ffget_outbound_propagation_nodeTb4b4b4(Tb4b4b4)

Te6edf3pn_app_data Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecall_app_dataTb4b4b4(Te6edf3pn_destination_hashTb4b4b4)

Tff7b72if Te6edf3pn_announce_data_is_validTb4b4b4(Te6edf3pn_app_dataTb4b4b4)Tb4b4b4:

Te6edf3pn_config Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3pn_app_dataTb4b4b4)

Te6edf3target_propagation_cost Tff7b72= Te6edf3pn_configTb4b4b4[T79c0ff5Tb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]

Tff7b72if Tff7b72not Te6edf3target_propagation_costTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffCould not retrieve cached propagation node config. Requesting path to propagation node to get target propagation cost...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffrequest_pathTb4b4b4(Te6edf3pn_destination_hashTb4b4b4)

Te6edf3timeout Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3LXMRouterTff7b72.Td2a8ffPATH_REQUEST_WAIT

Tff7b72while Tff7b72not Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecall_app_dataTb4b4b4(Te6edf3pn_destination_hashTb4b4b4) Tff7b72and Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72< Te6edf3timeoutTb4b4b4:

Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(T79c0ff0.5Tb4b4b4)

Te6edf3pn_app_data Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecall_app_dataTb4b4b4(Te6edf3pn_destination_hashTb4b4b4)

Tff7b72if Te6edf3pn_announce_data_is_validTb4b4b4(Te6edf3pn_app_dataTb4b4b4)Tb4b4b4:

Te6edf3pn_config Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3pn_app_dataTb4b4b4)

Te6edf3target_propagation_cost Tff7b72= Te6edf3pn_configTb4b4b4[T79c0ff5Tb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]

Tff7b72if Tff7b72not Te6edf3target_propagation_costTb4b4b4: Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffPropagation node stamp cost still unavailable after path requestTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72return Te6edf3target_propagation_cost

Tff7b72def Td2a8ffset_inbound_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

T8b949e# TODO: Implement

Tff7b72raise Tf85149NotImplementedErrorTb4b4b4(Ta5d6ff"Ta5d6ffInbound/outbound propagation node differentiation is currently not implementedTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffget_inbound_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffget_outbound_propagation_nodeTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffset_retain_node_lxmsTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3retainTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3retain Tff7b72== Tff7b72TrueTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffretain_synced_on_node Tff7b72= Tff7b72True

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffretain_synced_on_node Tff7b72= Tff7b72False

Tff7b72def Td2a8ffset_authenticationTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3requiredTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3required Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffauth_required Tff7b72= Te6edf3required

Tff7b72def Td2a8ffrequires_authenticationTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffauth_required

Tff7b72def Td2a8ffallowTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3identity_hashTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72and Tffa657lenTb4b4b4(Te6edf3identity_hashTb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3identity_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffallowed_listTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffallowed_listTff7b72.Td2a8ffappendTb4b4b4(Te6edf3identity_hashTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffAllowed identity hash must be Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff bytesTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffdisallowTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3identity_hashTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72and Tffa657lenTb4b4b4(Te6edf3identity_hashTb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4:

Tff7b72if Te6edf3identity_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffallowed_listTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffallowed_listTff7b72.Td2a8ffpopTb4b4b4(Te6edf3identity_hashTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffDisallowed identity hash must be Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff bytesTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffallow_controlTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3identity_hashTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72and Tffa657lenTb4b4b4(Te6edf3identity_hashTb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3identity_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4: Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTff7b72.Td2a8ffappendTb4b4b4(Te6edf3identity_hashTb4b4b4)

Tff7b72elseTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffAllowed identity hash must be Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff bytesTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffdisallow_controlTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3identity_hashTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72and Tffa657lenTb4b4b4(Te6edf3identity_hashTb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4:

Tff7b72if Te6edf3identity_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4: Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTff7b72.Td2a8ffpopTb4b4b4(Te6edf3identity_hashTb4b4b4)

Tff7b72elseTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffDisallowed identity hash must be Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff bytesTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffprioritiseTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3destination_hashTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72and Tffa657lenTb4b4b4(Te6edf3destination_hashTb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffReticulumTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffprioritised_listTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffprioritised_listTff7b72.Td2a8ffappendTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffPrioritised destination hash must be Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffReticulumTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff bytesTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffunprioritiseTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_hashTff7b72=Tff7b72NoneTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3destination_hashTb4b4b4, Tffa657bytesTb4b4b4) Tff7b72and Tffa657lenTb4b4b4(Te6edf3destination_hashTb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffReticulumTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffprioritised_listTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffprioritised_listTff7b72.Td2a8ffpopTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffPrioritised destination hash must be Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3RNSTff7b72.Td2a8ffReticulumTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff bytesTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffrequest_messages_from_propagation_nodeTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identityTb4b4b4, Te6edf3max_messages Tff7b72= Te6edf3PR_ALL_MESSAGESTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3max_messages Tff7b72== Tff7b72NoneTb4b4b4:

Te6edf3max_messages Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_ALL_MESSAGES

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_progress Tff7b72= T79c0ff0.0

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_max_messages Tff7b72= Te6edf3max_messages

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_node Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72!= Tff7b72None Tff7b72and Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffstatus Tff7b72== Te6edf3RNSTff7b72.Td2a8ffLinkTff7b72.Td2a8ffACTIVETb4b4b4:

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_LINK_ESTABLISHED

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffRequesting message list from propagation nodeTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffidentifyTb4b4b4(Te6edf3identityTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffrequestTb4b4b4(

Te6edf3LXMPeerTff7b72.Td2a8ffMESSAGE_GET_PATHTb4b4b4,

Tb4b4b4[Tff7b72NoneTb4b4b4, Tff7b72NoneTb4b4b4]Tb4b4b4, T8b949e# Set both want and have fields to None to get message list

Te6edf3response_callbackTff7b72=Tff7b72selfTff7b72.Td2a8ffmessage_list_responseTb4b4b4,

Te6edf3failed_callbackTff7b72=Tff7b72selfTff7b72.Td2a8ffmessage_get_failed

Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_REQUEST_SENT

Tff7b72elseTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72== Tff7b72NoneTb4b4b4:

Tff7b72if Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffhas_pathTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_nodeTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffwants_download_on_path_available_from Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_LINK_ESTABLISHING

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffEstablishing link to Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_nodeTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff for message downloadTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Te6edf3propagation_node_identity Tff7b72= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffrecallTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_nodeTb4b4b4)

Te6edf3propagation_node_destination Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTb4b4b4(Te6edf3propagation_node_identityTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffOUTTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffSINGLETb4b4b4, Te6edf3APP_NAMETb4b4b4, Ta5d6ff"Ta5d6ffpropagationTa5d6ff"Tb4b4b4)

Tff7b72def Td2a8ffmsg_request_established_callbackTb4b4b4(Te6edf3linkTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffrequest_messages_from_propagation_nodeTb4b4b4(Te6edf3identityTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_max_messagesTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72= Te6edf3RNSTff7b72.Td2a8ffLinkTb4b4b4(Te6edf3propagation_node_destinationTb4b4b4, Te6edf3established_callbackTff7b72=Te6edf3msg_request_established_callbackTb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffNo path known for message download from propagation node Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_nodeTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff. Requesting path...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffrequest_pathTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_nodeTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffwants_download_on_path_available_from Tff7b72= Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_node

Tff7b72selfTff7b72.Td2a8ffwants_download_on_path_available_to Tff7b72= Te6edf3identity

Tff7b72selfTff7b72.Td2a8ffwants_download_on_path_available_timeout Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3LXMRouterTff7b72.Td2a8ffPR_PATH_TIMEOUT

Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_PATH_REQUESTED

Tff7b72selfTff7b72.Td2a8ffrequest_messages_path_jobTb4b4b4(Tb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffWaiting for propagation node link to become activeTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_EXTREMETb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCannot request LXMF propagation node sync, no default propagation node configuredTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_WARNINGTb4b4b4)

Tff7b72def Td2a8ffcancel_propagation_node_requestsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72= Tff7b72None

Tff7b72selfTff7b72.Td2a8ffacknowledge_sync_completionTb4b4b4(Te6edf3reset_stateTff7b72=Tff7b72TrueTb4b4b4)

Tff7b72def Td2a8ffenable_propagationTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffmessagepath Tff7b72= Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/messagestoreTa5d6ff"

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffmessagepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffmessagepathTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_entries Tff7b72= Tb4b4b4{Tb4b4b4}

Te6edf3st Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4; Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffIndexing messagestore...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_NOTICETb4b4b4)

Tff7b72for Te6edf3filename Tff7b72in Te6edf3osTff7b72.Td2a8fflistdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffmessagepathTb4b4b4)Tb4b4b4:

Te6edf3components Tff7b72= Te6edf3filenameTff7b72.Td2a8ffsplitTb4b4b4(Ta5d6ff"Ta5d6ff_Ta5d6ff"Tb4b4b4)

Tff7b72if Tffa657lenTb4b4b4(Te6edf3componentsTb4b4b4) Tff7b72>Tff7b72= T79c0ff3Tb4b4b4:

Tff7b72if Tffa657floatTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4) Tff7b72== Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffHASHLENGTHTff7b72/Tff7b72/T79c0ff8Tff7b72*T79c0ff2Tb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3transient_id Tff7b72= Tffa657bytesTff7b72.Td2a8fffromhexTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4)

Te6edf3received Tff7b72= Tffa657floatTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4)

Te6edf3stamp_value Tff7b72= Tffa657intTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff2Tb4b4b4]Tb4b4b4)

Te6edf3filepath Tff7b72= Tff7b72selfTff7b72.Td2a8ffmessagepathTff7b72+Ta5d6ff"Ta5d6ff/Ta5d6ff"Tff7b72+Te6edf3filename

Te6edf3msg_size Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffgetsizeTb4b4b4(Te6edf3filepathTb4b4b4)

Te6edf3file Tff7b72= Tffa657openTb4b4b4(Te6edf3filepathTb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4)

Te6edf3destination_hash Tff7b72= Te6edf3fileTff7b72.Td2a8ffreadTb4b4b4(Te6edf3LXMessageTff7b72.Td2a8ffDESTINATION_LENGTHTb4b4b4)

Te6edf3fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4] Tff7b72= Tb4b4b4[

Te6edf3destination_hashTb4b4b4, T8b949e# 0: Destination hash

Te6edf3filepathTb4b4b4, T8b949e# 1: Storage location

Te6edf3receivedTb4b4b4, T8b949e# 2: Receive timestamp

Te6edf3msg_sizeTb4b4b4, T8b949e# 3: Message size

Tb4b4b4[Tb4b4b4]Tb4b4b4, T8b949e# 4: Handled peers

Tb4b4b4[Tb4b4b4]Tb4b4b4, T8b949e# 5: Unhandled peers

Te6edf3stamp_valueTb4b4b4, T8b949e# 6: Stamp value

Tb4b4b4]

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not read LXM from message store. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3et Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4; Te6edf3mps Tff7b72= T79c0ff0 Tff7b72if Te6edf3etTff7b72-Te6edf3st Tff7b72== T79c0ff0 Tff7b72else Te6edf3mathTff7b72.Td2a8fffloorTb4b4b4(Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4)Tff7b72/Tb4b4b4(Te6edf3etTff7b72-Te6edf3stTb4b4b4)Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffIndexed Tffd700{Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4)Tffd700}Ta5d6ff messages in Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettytimeTb4b4b4(Te6edf3etTff7b72-Te6edf3stTb4b4b4)Tffd700}Ta5d6ff, Tffd700{Te6edf3mpsTffd700}Ta5d6ff msgs/sTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_NOTICETb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffRebuilding peer synchronisation states...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_NOTICETb4b4b4)

Te6edf3st Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/peersTa5d6ff"Tb4b4b4)Tb4b4b4:

Te6edf3peers_file Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/peersTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4)

Te6edf3peers_data Tff7b72= Te6edf3peers_fileTff7b72.Td2a8ffreadTb4b4b4(Tb4b4b4)

Te6edf3peers_fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72if Tffa657lenTb4b4b4(Te6edf3peers_dataTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Te6edf3serialised_peers Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3peers_dataTb4b4b4)

Tff7b72del Te6edf3peers_data

Tff7b72while Tffa657lenTb4b4b4(Te6edf3serialised_peersTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Te6edf3serialised_peer Tff7b72= Te6edf3serialised_peersTff7b72.Td2a8ffpopTb4b4b4(Tb4b4b4)

Te6edf3peer Tff7b72= Te6edf3LXMPeerTff7b72.Td2a8fffrom_bytesTb4b4b4(Te6edf3serialised_peerTb4b4b4, Tff7b72selfTb4b4b4)

Tff7b72del Te6edf3serialised_peer

Tff7b72if Te6edf3peerTff7b72.Td2a8ffdestination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffstatic_peers Tff7b72and Te6edf3peerTff7b72.Td2a8fflast_heard Tff7b72== T79c0ff0Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffrequest_pathTb4b4b4(Te6edf3peerTff7b72.Td2a8ffdestination_hashTb4b4b4)

Tff7b72if Te6edf3peerTff7b72.Td2a8ffidentity Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4[Te6edf3peerTff7b72.Td2a8ffdestination_hashTb4b4b4] Tff7b72= Te6edf3peer

Te6edf3lim_str Tff7b72= Ta5d6ff"Ta5d6ff, no transfer limitTa5d6ff"

Tff7b72if Te6edf3peerTff7b72.Td2a8ffpropagation_transfer_limit Tff7b72!= Tff7b72NoneTb4b4b4:

Te6edf3lim_str Tff7b72= Ta5d6ff"Ta5d6ff, Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Te6edf3peerTff7b72.Td2a8ffpropagation_transfer_limitTff7b72*T79c0ff1000Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff transfer limitTa5d6ff"

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffRebuilt peer Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3peerTff7b72.Td2a8ffdestination_hashTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff with Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3peerTff7b72.Td2a8ffunhandled_message_countTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff unhandled messagesTa5d6ff"Tff7b72+Te6edf3lim_strTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffPeer Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3peerTff7b72.Td2a8ffdestination_hashTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff could not be loaded, because its identity could not be recalled. Dropping peer.Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72del Te6edf3peer

Tff7b72del Te6edf3serialised_peers

Tff7b72if Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstatic_peersTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72for Te6edf3static_peer Tff7b72in Tff7b72selfTff7b72.Td2a8ffstatic_peersTb4b4b4:

Tff7b72if Tff7b72not Te6edf3static_peer Tff7b72in Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffActivating static peering with Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3static_peerTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_NOTICETb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4[Te6edf3static_peerTb4b4b4] Tff7b72= Te6edf3LXMPeerTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3static_peerTb4b4b4, Te6edf3sync_strategyTff7b72=Tff7b72selfTff7b72.Td2a8ffdefault_sync_strategyTb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4[Te6edf3static_peerTb4b4b4]Tff7b72.Td2a8fflast_heard Tff7b72== T79c0ff0Tb4b4b4:

T8b949e# TODO: Allow path request responses through announce handler

T8b949e# momentarily here, so peering config can be updated even if

T8b949e# the static peer is not available to directly send an announce.

Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffrequest_pathTb4b4b4(Te6edf3static_peerTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffRebuilt synchronisation state for Tffd700{Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4)Tffd700}Ta5d6ff peers in Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettytimeTb4b4b4(Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tff7b72-Te6edf3stTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_NOTICETb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/node_statsTa5d6ff"Tb4b4b4)Tb4b4b4:

Te6edf3node_stats_file Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/node_statsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffrbTa5d6ff"Tb4b4b4)

Te6edf3data Tff7b72= Te6edf3node_stats_fileTff7b72.Td2a8ffreadTb4b4b4(Tb4b4b4)

Te6edf3node_stats_fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Te6edf3node_stats Tff7b72= Te6edf3msgpackTff7b72.Td2a8ffunpackbTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72if Tff7b72not Tffa657typeTb4b4b4(Te6edf3node_statsTb4b4b4) Tff7b72== Tffa657dictTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffInvalid data format for loaded local node stats, node stats will be resetTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_received Tff7b72= Te6edf3node_statsTb4b4b4[Ta5d6ff"Ta5d6ffclient_propagation_messages_receivedTa5d6ff"Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_served Tff7b72= Te6edf3node_statsTb4b4b4[Ta5d6ff"Ta5d6ffclient_propagation_messages_servedTa5d6ff"Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_incoming Tff7b72= Te6edf3node_statsTb4b4b4[Ta5d6ff"Ta5d6ffunpeered_propagation_incomingTa5d6ff"Tb4b4b4]

Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_rx_bytes Tff7b72= Te6edf3node_statsTb4b4b4[Ta5d6ff"Ta5d6ffunpeered_propagation_rx_bytesTa5d6ff"Tb4b4b4]

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not load local node stats. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72= Tff7b72True

Tff7b72selfTff7b72.Td2a8ffpropagation_node_start_time Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffset_link_established_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_link_establishedTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffset_packet_callbackTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_packetTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffregister_request_handlerTb4b4b4(Te6edf3LXMPeerTff7b72.Td2a8ffOFFER_REQUEST_PATHTb4b4b4, Tff7b72selfTff7b72.Td2a8ffoffer_requestTb4b4b4, Te6edf3allow Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffALLOW_ALLTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffregister_request_handlerTb4b4b4(Te6edf3LXMPeerTff7b72.Td2a8ffMESSAGE_GET_PATHTb4b4b4, Tff7b72selfTff7b72.Td2a8ffmessage_get_requestTb4b4b4, Te6edf3allow Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffALLOW_ALLTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_list Tff7b72= Tb4b4b4[Tff7b72selfTff7b72.Td2a8ffidentityTff7b72.Td2a8ffhashTb4b4b4]

Tff7b72selfTff7b72.Td2a8ffcontrol_destination Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTb4b4b4(Tff7b72selfTff7b72.Td2a8ffidentityTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffINTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffSINGLETb4b4b4, Te6edf3APP_NAMETb4b4b4, Ta5d6ff"Ta5d6ffpropagationTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffcontrolTa5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffcontrol_destinationTff7b72.Td2a8ffregister_request_handlerTb4b4b4(Te6edf3LXMRouterTff7b72.Td2a8ffSTATS_GET_PATHTb4b4b4, Tff7b72selfTff7b72.Td2a8ffstats_get_requestTb4b4b4, Te6edf3allow Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffALLOW_LISTTb4b4b4, Te6edf3allowed_listTff7b72=Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffcontrol_destinationTff7b72.Td2a8ffregister_request_handlerTb4b4b4(Te6edf3LXMRouterTff7b72.Td2a8ffSYNC_REQUEST_PATHTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpeer_sync_requestTb4b4b4, Te6edf3allow Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffALLOW_LISTTb4b4b4, Te6edf3allowed_listTff7b72=Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffcontrol_destinationTff7b72.Td2a8ffregister_request_handlerTb4b4b4(Te6edf3LXMRouterTff7b72.Td2a8ffUNPEER_REQUEST_PATHTb4b4b4, Tff7b72selfTff7b72.Td2a8ffpeer_unpeer_requestTb4b4b4, Te6edf3allow Tff7b72= Te6edf3RNSTff7b72.Td2a8ffDestinationTff7b72.Td2a8ffALLOW_LISTTb4b4b4, Te6edf3allowed_listTff7b72=Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffmessage_storage_limit Tff7b72!= Tff7b72NoneTb4b4b4:

Te6edf3limit_str Tff7b72= Ta5d6ff"Ta5d6ff, limit is Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Tff7b72selfTff7b72.Td2a8ffmessage_storage_limitTb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3limit_str Tff7b72= Ta5d6ff"Ta5d6ff"

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffLXMF Propagation Node message store size is Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Tff7b72selfTff7b72.Td2a8ffmessage_storage_sizeTb4b4b4(Tb4b4b4)Tb4b4b4)Tff7b72+Te6edf3limit_strTb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffannounce_propagation_nodeTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not enable propagation node. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72raise Te6edf3e

Te6edf3RNSTff7b72.Td2a8ffpanicTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffdisable_propagationTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72= Tff7b72False

Tff7b72selfTff7b72.Td2a8ffannounce_propagation_nodeTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffenforce_stampsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_enforce_stamps Tff7b72= Tff7b72True

Tff7b72def Td2a8ffignore_stampsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_enforce_stamps Tff7b72= Tff7b72False

Tff7b72def Td2a8ffignore_destinationTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffignored_listTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffignored_listTff7b72.Td2a8ffappendTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72def Td2a8ffunignore_destinationTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffignored_listTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffignored_listTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72def Td2a8ffset_message_storage_limitTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3kilobytes Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3megabytes Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3gigabytes Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Te6edf3limit_bytes Tff7b72= T79c0ff0

Tff7b72if Te6edf3kilobytes Tff7b72!= Tff7b72NoneTb4b4b4:

Te6edf3limit_bytes Tff7b72+Tff7b72= Te6edf3kilobytesTff7b72*T79c0ff1000

Tff7b72if Te6edf3megabytes Tff7b72!= Tff7b72NoneTb4b4b4:

Te6edf3limit_bytes Tff7b72+Tff7b72= Te6edf3megabytesTff7b72*T79c0ff1000Tff7b72*T79c0ff1000

Tff7b72if Te6edf3gigabytes Tff7b72!= Tff7b72NoneTb4b4b4:

Te6edf3limit_bytes Tff7b72+Tff7b72= Te6edf3gigabytesTff7b72*T79c0ff1000Tff7b72*T79c0ff1000Tff7b72*T79c0ff1000

Tff7b72if Te6edf3limit_bytes Tff7b72== T79c0ff0Tb4b4b4:

Te6edf3limit_bytes Tff7b72= Tff7b72None

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3limit_bytes Tff7b72== Tff7b72None Tff7b72or Tffa657intTb4b4b4(Te6edf3limit_bytesTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffmessage_storage_limit Tff7b72= Tffa657intTb4b4b4(Te6edf3limit_bytesTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffCannot set LXMF information storage limit to Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3limit_bytesTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffCannot set LXMF information storage limit to Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3limit_bytesTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffmessage_storage_limitTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffmessage_storage_limit

Tff7b72def Td2a8ffmessage_storage_sizeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpropagation_nodeTb4b4b4:

Tff7b72return Tffa657sumTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3fTb4b4b4]Tb4b4b4[T79c0ff3Tb4b4b4] Tff7b72for Te6edf3f Tff7b72in Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72return Tff7b72None

Tff7b72def Td2a8ffset_information_storage_limitTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3kilobytes Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3megabytes Tff7b72= Tff7b72NoneTb4b4b4, Te6edf3gigabytes Tff7b72= Tff7b72NoneTb4b4b4)Tb4b4b4:

Te6edf3limit_bytes Tff7b72= T79c0ff0

Tff7b72if Te6edf3kilobytes Tff7b72!= Tff7b72NoneTb4b4b4: Te6edf3limit_bytes Tff7b72+Tff7b72= Te6edf3kilobytesTff7b72*T79c0ff1000

Tff7b72if Te6edf3megabytes Tff7b72!= Tff7b72NoneTb4b4b4: Te6edf3limit_bytes Tff7b72+Tff7b72= Te6edf3megabytesTff7b72*T79c0ff1000Tff7b72*T79c0ff1000

Tff7b72if Te6edf3gigabytes Tff7b72!= Tff7b72NoneTb4b4b4: Te6edf3limit_bytes Tff7b72+Tff7b72= Te6edf3gigabytesTff7b72*T79c0ff1000Tff7b72*T79c0ff1000Tff7b72*T79c0ff1000

Tff7b72if Te6edf3limit_bytes Tff7b72== T79c0ff0Tb4b4b4: Te6edf3limit_bytes Tff7b72= Tff7b72None

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3limit_bytes Tff7b72== Tff7b72None Tff7b72or Tffa657intTb4b4b4(Te6edf3limit_bytesTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffinformation_storage_limit Tff7b72= Tffa657intTb4b4b4(Te6edf3limit_bytesTb4b4b4)

Tff7b72elseTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffCannot set LXMF information storage limit to Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3limit_bytesTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4: Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffCannot set LXMF information storage limit to Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3limit_bytesTb4b4b4)Tb4b4b4)

Tff7b72def Td2a8ffinformation_storage_limitTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72return Tff7b72selfTff7b72.Td2a8ffinformation_storage_limit

Tff7b72def Td2a8ffinformation_storage_sizeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72pass

Tff7b72def Td2a8ffdelivery_link_availableTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffdirect_links Tff7b72or Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffbackchannel_linksTb4b4b4: Tff7b72return Tff7b72True

Tff7b72elseTb4b4b4: Tff7b72return Tff7b72False

T8b949e### Propagation Node Control ##########################

T8b949e#######################################################

Tff7b72def Td2a8ffcompile_statsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffpropagation_nodeTb4b4b4: Tff7b72return Tff7b72None

Tff7b72elseTb4b4b4:

Te6edf3peer_stats Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72for Te6edf3peer_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffpeersTff7b72.Td2a8ffcopyTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3peer Tff7b72= Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4[Te6edf3peer_idTb4b4b4]

Te6edf3peer_statsTb4b4b4[Te6edf3peer_idTb4b4b4] Tff7b72= Tb4b4b4{

Ta5d6ff"Ta5d6fftypeTa5d6ff"Tb4b4b4: Ta5d6ff"Ta5d6ffstaticTa5d6ff" Tff7b72if Te6edf3peer_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffstatic_peers Tff7b72else Ta5d6ff"Ta5d6ffdiscoveredTa5d6ff"Tb4b4b4,

Ta5d6ff"Ta5d6ffstateTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffstateTb4b4b4,

Ta5d6ff"Ta5d6ffaliveTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffaliveTb4b4b4,

Ta5d6ff"Ta5d6ffnameTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffnameTb4b4b4,

Ta5d6ff"Ta5d6fflast_heardTa5d6ff"Tb4b4b4: Tffa657intTb4b4b4(Te6edf3peerTff7b72.Td2a8fflast_heardTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffnext_sync_attemptTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffnext_sync_attemptTb4b4b4,

Ta5d6ff"Ta5d6fflast_sync_attemptTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8fflast_sync_attemptTb4b4b4,

Ta5d6ff"Ta5d6ffsync_backoffTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffsync_backoffTb4b4b4,

Ta5d6ff"Ta5d6ffpeering_timebaseTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpeering_timebaseTb4b4b4,

Ta5d6ff"Ta5d6fflerTa5d6ff"Tb4b4b4: Tffa657intTb4b4b4(Te6edf3peerTff7b72.Td2a8fflink_establishment_rateTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffstrTa5d6ff"Tb4b4b4: Tffa657intTb4b4b4(Te6edf3peerTff7b72.Td2a8ffsync_transfer_rateTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6fftransfer_limitTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpropagation_transfer_limitTb4b4b4,

Ta5d6ff"Ta5d6ffsync_limitTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpropagation_sync_limitTb4b4b4,

Ta5d6ff"Ta5d6fftarget_stamp_costTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpropagation_stamp_costTb4b4b4,

Ta5d6ff"Ta5d6ffstamp_cost_flexibilityTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpropagation_stamp_cost_flexibilityTb4b4b4,

Ta5d6ff"Ta5d6ffpeering_costTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpeering_costTb4b4b4,

Ta5d6ff"Ta5d6ffpeering_keyTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffpeering_key_valueTb4b4b4(Tb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffnetwork_distanceTa5d6ff"Tb4b4b4: Te6edf3RNSTff7b72.Td2a8ffTransportTff7b72.Td2a8ffhops_toTb4b4b4(Te6edf3peer_idTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffrx_bytesTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffrx_bytesTb4b4b4,

Ta5d6ff"Ta5d6fftx_bytesTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8fftx_bytesTb4b4b4,

Ta5d6ff"Ta5d6ffacceptance_rateTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffacceptance_rateTb4b4b4,

Ta5d6ff"Ta5d6ffmessagesTa5d6ff"Tb4b4b4: Tb4b4b4{

Ta5d6ff"Ta5d6ffofferedTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffofferedTb4b4b4,

Ta5d6ff"Ta5d6ffoutgoingTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffoutgoingTb4b4b4,

Ta5d6ff"Ta5d6ffincomingTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffincomingTb4b4b4,

Ta5d6ff"Ta5d6ffunhandledTa5d6ff"Tb4b4b4: Te6edf3peerTff7b72.Td2a8ffunhandled_message_count

Tb4b4b4}Tb4b4b4,

Tb4b4b4}

Te6edf3node_stats Tff7b72= Tb4b4b4{

Ta5d6ff"Ta5d6ffidentity_hashTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffidentityTff7b72.Td2a8ffhashTb4b4b4,

Ta5d6ff"Ta5d6ffdestination_hashTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpropagation_destinationTff7b72.Td2a8ffhashTb4b4b4,

Ta5d6ff"Ta5d6ffuptimeTa5d6ff"Tb4b4b4: Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tff7b72-Tff7b72selfTff7b72.Td2a8ffpropagation_node_start_timeTb4b4b4,

Ta5d6ff"Ta5d6ffdelivery_limitTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffdelivery_per_transfer_limitTb4b4b4,

Ta5d6ff"Ta5d6ffpropagation_limitTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpropagation_per_transfer_limitTb4b4b4,

Ta5d6ff"Ta5d6ffsync_limitTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpropagation_per_sync_limitTb4b4b4,

Ta5d6ff"Ta5d6fftarget_stamp_costTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpropagation_stamp_costTb4b4b4,

Ta5d6ff"Ta5d6ffstamp_cost_flexibilityTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpropagation_stamp_cost_flexibilityTb4b4b4,

Ta5d6ff"Ta5d6ffpeering_costTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpeering_costTb4b4b4,

Ta5d6ff"Ta5d6ffmax_peering_costTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmax_peering_costTb4b4b4,

Ta5d6ff"Ta5d6ffautopeer_maxdepthTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffautopeer_maxdepthTb4b4b4,

Ta5d6ff"Ta5d6fffrom_static_onlyTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8fffrom_static_onlyTb4b4b4,

Ta5d6ff"Ta5d6ffmessagestoreTa5d6ff"Tb4b4b4: Tb4b4b4{

Ta5d6ff"Ta5d6ffcountTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffbytesTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmessage_storage_sizeTb4b4b4(Tb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6fflimitTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmessage_storage_limitTb4b4b4,

Tb4b4b4}Tb4b4b4,

Ta5d6ff"Ta5d6ffclientsTa5d6ff" Tb4b4b4: Tb4b4b4{

Ta5d6ff"Ta5d6ffclient_propagation_messages_receivedTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_receivedTb4b4b4,

Ta5d6ff"Ta5d6ffclient_propagation_messages_servedTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_servedTb4b4b4,

Tb4b4b4}Tb4b4b4,

Ta5d6ff"Ta5d6ffunpeered_propagation_incomingTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_incomingTb4b4b4,

Ta5d6ff"Ta5d6ffunpeered_propagation_rx_bytesTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_rx_bytesTb4b4b4,

Ta5d6ff"Ta5d6ffstatic_peersTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstatic_peersTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffdiscovered_peersTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4)Tff7b72-Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstatic_peersTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6fftotal_peersTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4)Tb4b4b4,

Ta5d6ff"Ta5d6ffmax_peersTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmax_peersTb4b4b4,

Ta5d6ff"Ta5d6ffpeersTa5d6ff"Tb4b4b4: Te6edf3peer_statsTb4b4b4,

Tb4b4b4}

Tff7b72return Te6edf3node_stats

Tff7b72def Td2a8ffstats_get_requestTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3pathTb4b4b4, Te6edf3dataTb4b4b4, Te6edf3request_idTb4b4b4, Te6edf3remote_identityTb4b4b4, Te6edf3requested_atTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3remote_identity Tff7b72== Tff7b72NoneTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NO_IDENTITY

Tff7b72elif Te6edf3remote_identityTff7b72.Td2a8ffhash Tff7b72not Tff7b72in Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NO_ACCESS

Tff7b72elseTb4b4b4: Tff7b72return Tff7b72selfTff7b72.Td2a8ffcompile_statsTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffpeer_sync_requestTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3pathTb4b4b4, Te6edf3dataTb4b4b4, Te6edf3request_idTb4b4b4, Te6edf3remote_identityTb4b4b4, Te6edf3requested_atTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3remote_identity Tff7b72== Tff7b72NoneTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NO_IDENTITY

Tff7b72elif Te6edf3remote_identityTff7b72.Td2a8ffhash Tff7b72not Tff7b72in Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NO_ACCESS

Tff7b72elseTb4b4b4:

Tff7b72if Tffa657typeTb4b4b4(Te6edf3dataTb4b4b4) Tff7b72!= Tffa657bytesTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_INVALID_DATA

Tff7b72elif Tffa657lenTb4b4b4(Te6edf3dataTb4b4b4) Tff7b72!= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_INVALID_DATA

Tff7b72elseTb4b4b4:

Tff7b72if Tff7b72not Te6edf3data Tff7b72in Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NOT_FOUND

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4[Te6edf3dataTb4b4b4]Tff7b72.Td2a8ffsyncTb4b4b4(Tb4b4b4)

Tff7b72return Tff7b72True

Tff7b72def Td2a8ffpeer_unpeer_requestTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3pathTb4b4b4, Te6edf3dataTb4b4b4, Te6edf3request_idTb4b4b4, Te6edf3remote_identityTb4b4b4, Te6edf3requested_atTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3remote_identity Tff7b72== Tff7b72NoneTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NO_IDENTITY

Tff7b72elif Te6edf3remote_identityTff7b72.Td2a8ffhash Tff7b72not Tff7b72in Tff7b72selfTff7b72.Td2a8ffcontrol_allowed_listTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NO_ACCESS

Tff7b72elseTb4b4b4:

Tff7b72if Tffa657typeTb4b4b4(Te6edf3dataTb4b4b4) Tff7b72!= Tffa657bytesTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_INVALID_DATA

Tff7b72elif Tffa657lenTb4b4b4(Te6edf3dataTb4b4b4) Tff7b72!= Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffTRUNCATED_HASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_INVALID_DATA

Tff7b72elseTb4b4b4:

Tff7b72if Tff7b72not Te6edf3data Tff7b72in Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4: Tff7b72return Te6edf3LXMPeerTff7b72.Td2a8ffERROR_NOT_FOUND

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffunpeerTb4b4b4(Te6edf3dataTb4b4b4)

Tff7b72return Tff7b72True

T8b949e### Utility & Maintenance #############################

T8b949e#######################################################

Te6edf3JOB_OUTBOUND_INTERVAL Tff7b72= T79c0ff1

Te6edf3JOB_STAMPS_INTERVAL Tff7b72= T79c0ff1

Te6edf3JOB_LINKS_INTERVAL Tff7b72= T79c0ff1

Te6edf3JOB_TRANSIENT_INTERVAL Tff7b72= T79c0ff60

Te6edf3JOB_STORE_INTERVAL Tff7b72= T79c0ff120

Te6edf3JOB_PEERSYNC_INTERVAL Tff7b72= T79c0ff6

Te6edf3JOB_PEERINGEST_INTERVALTff7b72= Te6edf3JOB_PEERSYNC_INTERVAL

Te6edf3JOB_ROTATE_INTERVAL Tff7b72= T79c0ff56Tff7b72*Te6edf3JOB_PEERINGEST_INTERVAL

Tff7b72def Td2a8ffjobsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72not Tff7b72selfTff7b72.Td2a8ffexit_handler_runningTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72+Tff7b72= T79c0ff1

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_OUTBOUND_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffprocess_outboundTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_STAMPS_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ffprocess_deferred_stampsTb4b4b4, Te6edf3daemonTff7b72=Tff7b72TrueTb4b4b4)Tff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_LINKS_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffclean_linksTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_TRANSIENT_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffclean_transient_id_cachesTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_STORE_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72== Tff7b72TrueTb4b4b4: Tff7b72selfTff7b72.Td2a8ffclean_message_storeTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_PEERINGEST_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72== Tff7b72TrueTb4b4b4: Tff7b72selfTff7b72.Td2a8ffflush_queuesTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_ROTATE_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72== Tff7b72TrueTb4b4b4: Tff7b72selfTff7b72.Td2a8ffrotate_peersTb4b4b4(Tb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffprocessing_count Tff7b72% Te6edf3LXMRouterTff7b72.Td2a8ffJOB_PEERSYNC_INTERVAL Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpropagation_node Tff7b72== Tff7b72TrueTb4b4b4: Tff7b72selfTff7b72.Td2a8ffsync_peersTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ffclean_throttled_peersTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffjobloopTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72while Tb4b4b4(Tff7b72TrueTb4b4b4)Tb4b4b4:

T8b949e# TODO: Improve this to scheduling, so manual

T8b949e# triggers can delay next run

Tff7b72tryTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffjobsTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffAn error ocurred while running LXMF Router jobs.Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffThe contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fftrace_exceptionTb4b4b4(Te6edf3eTb4b4b4)

Te6edf3timeTff7b72.Td2a8ffsleepTb4b4b4(Te6edf3LXMRouterTff7b72.Td2a8ffPROCESSING_INTERVALTb4b4b4)

Tff7b72def Td2a8ffflush_queuesTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffflush_peer_distribution_queueTb4b4b4(Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCalculating peer distribution queue mappings...Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)Tb4b4b4; Te6edf3st Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Tff7b72for Te6edf3peer_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffpeersTff7b72.Td2a8ffcopyTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3peer_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4:

Te6edf3peer Tff7b72= Tff7b72selfTff7b72.Td2a8ffpeersTb4b4b4[Te6edf3peer_idTb4b4b4]

Tff7b72if Te6edf3peerTff7b72.Td2a8ffqueued_itemsTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3peerTff7b72.Td2a8ffprocess_queuesTb4b4b4(Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffDistribution queue mapping completed in Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettytimeTb4b4b4(Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tff7b72-Te6edf3stTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72def Td2a8ffclean_linksTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3closed_links Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3link_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffdirect_linksTb4b4b4:

Te6edf3link Tff7b72= Tff7b72selfTff7b72.Td2a8ffdirect_linksTb4b4b4[Te6edf3link_hashTb4b4b4]

Te6edf3inactive_time Tff7b72= Te6edf3linkTff7b72.Td2a8ffno_data_forTb4b4b4(Tb4b4b4)

Tff7b72if Te6edf3inactive_time Tff7b72> Te6edf3LXMRouterTff7b72.Td2a8ffLINK_MAX_INACTIVITYTb4b4b4:

Te6edf3linkTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Te6edf3closed_linksTff7b72.Td2a8ffappendTb4b4b4(Te6edf3link_hashTb4b4b4)

Tff7b72if Te6edf3linkTff7b72.Td2a8fflink_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffvalidated_peer_linksTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffvalidated_peer_linksTff7b72.Td2a8ffpopTb4b4b4(Te6edf3linkTff7b72.Td2a8fflink_idTb4b4b4)

Tff7b72for Te6edf3link_hash Tff7b72in Te6edf3closed_linksTb4b4b4:

Te6edf3cleaned_link Tff7b72= Tff7b72selfTff7b72.Td2a8ffdirect_linksTff7b72.Td2a8ffpopTb4b4b4(Te6edf3link_hashTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCleaned link Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3cleaned_linkTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72tryTb4b4b4:

Te6edf3inactive_links Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3link Tff7b72in Tff7b72selfTff7b72.Td2a8ffactive_propagation_linksTb4b4b4:

Tff7b72if Te6edf3linkTff7b72.Td2a8ffno_data_forTb4b4b4(Tb4b4b4) Tff7b72> Te6edf3LXMRouterTff7b72.Td2a8ffP_LINK_MAX_INACTIVITYTb4b4b4:

Te6edf3inactive_linksTff7b72.Td2a8ffappendTb4b4b4(Te6edf3linkTb4b4b4)

Tff7b72for Te6edf3link Tff7b72in Te6edf3inactive_linksTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffactive_propagation_linksTff7b72.Td2a8ffremoveTb4b4b4(Te6edf3linkTb4b4b4)

Te6edf3linkTff7b72.Td2a8ffteardownTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffAn error occurred while cleaning inbound propagation links. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72if Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72!= Tff7b72None Tff7b72and Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_linkTff7b72.Td2a8ffstatus Tff7b72== Te6edf3RNSTff7b72.Td2a8ffLinkTff7b72.Td2a8ffCLOSEDTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffoutbound_propagation_link Tff7b72= Tff7b72None

Tff7b72if Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72== Te6edf3LXMRouterTff7b72.Td2a8ffPR_COMPLETETb4b4b4:

Tff7b72selfTff7b72.Td2a8ffacknowledge_sync_completionTb4b4b4(Tb4b4b4)

Tff7b72elif Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72< Te6edf3LXMRouterTff7b72.Td2a8ffPR_LINK_ESTABLISHEDTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffacknowledge_sync_completionTb4b4b4(Te6edf3failure_stateTff7b72=Te6edf3LXMRouterTff7b72.Td2a8ffPR_LINK_FAILEDTb4b4b4)

Tff7b72elif Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72>Tff7b72= Te6edf3LXMRouterTff7b72.Td2a8ffPR_LINK_ESTABLISHED Tff7b72and Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_state Tff7b72< Te6edf3LXMRouterTff7b72.Td2a8ffPR_COMPLETETb4b4b4:

Tff7b72selfTff7b72.Td2a8ffacknowledge_sync_completionTb4b4b4(Te6edf3failure_stateTff7b72=Te6edf3LXMRouterTff7b72.Td2a8ffPR_TRANSFER_FAILEDTb4b4b4)

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffUnknown propagation transfer state on link cleaning: Tffd700{Tff7b72selfTff7b72.Td2a8ffpropagation_transfer_stateTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffacknowledge_sync_completionTb4b4b4(Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCleaned outbound propagation linkTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72def Td2a8ffclean_transient_id_cachesTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3now Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3removed_entries Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3transient_id Tff7b72in Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_idsTb4b4b4:

Te6edf3timestamp Tff7b72= Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_idsTb4b4b4[Te6edf3transient_idTb4b4b4]

Tff7b72if Te6edf3now Tff7b72> Te6edf3timestampTff7b72+Te6edf3LXMRouterTff7b72.Td2a8ffMESSAGE_EXPIRYTff7b72*T79c0ff6.0Tb4b4b4:

Te6edf3removed_entriesTff7b72.Td2a8ffappendTb4b4b4(Te6edf3transient_idTb4b4b4)

Tff7b72for Te6edf3transient_id Tff7b72in Te6edf3removed_entriesTb4b4b4:

Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_idsTff7b72.Td2a8ffpopTb4b4b4(Te6edf3transient_idTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCleaned Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3transient_idTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff from local delivery cacheTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Te6edf3removed_entries Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3transient_id Tff7b72in Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_idsTb4b4b4:

Te6edf3timestamp Tff7b72= Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_idsTb4b4b4[Te6edf3transient_idTb4b4b4]

Tff7b72if Te6edf3now Tff7b72> Te6edf3timestampTff7b72+Te6edf3LXMRouterTff7b72.Td2a8ffMESSAGE_EXPIRYTff7b72*T79c0ff6.0Tb4b4b4:

Te6edf3removed_entriesTff7b72.Td2a8ffappendTb4b4b4(Te6edf3transient_idTb4b4b4)

Tff7b72for Te6edf3transient_id Tff7b72in Te6edf3removed_entriesTb4b4b4:

Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_idsTff7b72.Td2a8ffpopTb4b4b4(Te6edf3transient_idTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCleaned Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3transient_idTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff from locally processed cacheTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72def Td2a8ffupdate_stamp_costTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4, Te6edf3stamp_costTb4b4b4)Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffUpdating outbound stamp cost for Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3destination_hashTb4b4b4)Tffd700}Ta5d6ff to Tffd700{Te6edf3stamp_costTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4[Te6edf3destination_hashTb4b4b4] Tff7b72= Tb4b4b4[Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3stamp_costTb4b4b4]

Tff7b72def Td2a8ffjobTb4b4b4(Tb4b4b4)Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffsave_outbound_stamp_costsTb4b4b4(Tb4b4b4)

Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ffsave_outbound_stamp_costsTb4b4b4, Te6edf3daemonTff7b72=Tff7b72TrueTb4b4b4)Tff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffget_announce_app_dataTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4:

Te6edf3delivery_destination Tff7b72= Tff7b72selfTff7b72.Td2a8ffdelivery_destinationsTb4b4b4[Te6edf3destination_hashTb4b4b4]

Te6edf3display_name Tff7b72= Tff7b72None

Tff7b72if Te6edf3delivery_destinationTff7b72.Td2a8ffdisplay_name Tff7b72!= Tff7b72NoneTb4b4b4:

Te6edf3display_name Tff7b72= Te6edf3delivery_destinationTff7b72.Td2a8ffdisplay_nameTff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4)

Te6edf3stamp_cost Tff7b72= Tff7b72None

Tff7b72if Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost Tff7b72!= Tff7b72None Tff7b72and Tffa657typeTb4b4b4(Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_costTb4b4b4) Tff7b72== Tffa657intTb4b4b4:

Tff7b72if Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost Tff7b72> T79c0ff0 Tff7b72and Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost Tff7b72< T79c0ff255Tb4b4b4:

Te6edf3stamp_cost Tff7b72= Te6edf3delivery_destinationTff7b72.Td2a8ffstamp_cost

Te6edf3peer_data Tff7b72= Tb4b4b4[Te6edf3display_nameTb4b4b4, Te6edf3stamp_costTb4b4b4]

Tff7b72return Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Te6edf3peer_dataTb4b4b4)

Tff7b72def Td2a8ffget_sizeTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3transient_idTb4b4b4)Tb4b4b4:

Te6edf3lxm_size Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]Tb4b4b4[T79c0ff3Tb4b4b4]

Tff7b72return Te6edf3lxm_size

Tff7b72def Td2a8ffget_weightTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3transient_idTb4b4b4)Tb4b4b4:

Te6edf3dst_hash Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]

Te6edf3lxm_rcvd Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]Tb4b4b4[T79c0ff2Tb4b4b4]

Te6edf3lxm_size Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]Tb4b4b4[T79c0ff3Tb4b4b4]

Te6edf3now Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3age_weight Tff7b72= Tffa657maxTb4b4b4(T79c0ff1Tb4b4b4, Tb4b4b4(Te6edf3now Tff7b72- Te6edf3lxm_rcvdTb4b4b4)Tff7b72/T79c0ff60Tff7b72/T79c0ff60Tff7b72/T79c0ff24Tff7b72/T79c0ff4Tb4b4b4)

Tff7b72if Te6edf3dst_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffprioritised_listTb4b4b4: Te6edf3priority_weight Tff7b72= T79c0ff0.1

Tff7b72elseTb4b4b4: Te6edf3priority_weight Tff7b72= T79c0ff1.0

Tff7b72return Te6edf3priority_weight Tff7b72* Te6edf3age_weight Tff7b72* Te6edf3lxm_size

Tff7b72def Td2a8ffget_stamp_valueTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3transient_idTb4b4b4)Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3transient_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4: Tff7b72return Tff7b72None

Tff7b72elseTb4b4b4: Tff7b72return Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]Tb4b4b4[T79c0ff6Tb4b4b4]

Tff7b72def Td2a8ffgenerate_ticketTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4, Te6edf3expiryTff7b72=Te6edf3LXMessageTff7b72.Td2a8ffTICKET_EXPIRYTb4b4b4)Tb4b4b4:

Te6edf3now Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3ticket Tff7b72= Tff7b72None

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6fflast_deliveriesTa5d6ff"Tb4b4b4]Tb4b4b4:

Te6edf3last_delivery Tff7b72= Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6fflast_deliveriesTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]

Te6edf3elapsed Tff7b72= Te6edf3now Tff7b72- Te6edf3last_delivery

Tff7b72if Te6edf3elapsed Tff7b72< Te6edf3LXMessageTff7b72.Td2a8ffTICKET_INTERVALTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffA ticket for Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3destination_hashTb4b4b4)Tffd700}Ta5d6ff was already delivered Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettytimeTb4b4b4(Te6edf3elapsedTb4b4b4)Tffd700}Ta5d6ff ago, not including another ticket yetTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72return Tff7b72None

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4:

Tff7b72for Te6edf3ticket Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4:

Te6edf3ticket_entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4[Te6edf3ticketTb4b4b4]

Te6edf3expires Tff7b72= Te6edf3ticket_entryTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4; Te6edf3validity_left Tff7b72= Te6edf3expires Tff7b72- Te6edf3now

Tff7b72if Te6edf3validity_left Tff7b72> Te6edf3LXMessageTff7b72.Td2a8ffTICKET_RENEWTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffFound generated ticket for Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3destination_hashTb4b4b4)Tffd700}Ta5d6ff with Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettytimeTb4b4b4(Te6edf3validity_leftTb4b4b4)Tffd700}Ta5d6ff of validity left, re-using this oneTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72return Tb4b4b4[Te6edf3expiresTb4b4b4, Te6edf3ticketTb4b4b4]

Tff7b72elseTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4] Tff7b72= Tb4b4b4{Tb4b4b4}

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffNo generated tickets for Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3destination_hashTb4b4b4)Tffd700}Ta5d6ff with enough validity found, generating a new oneTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Te6edf3expires Tff7b72= Te6edf3nowTff7b72+Te6edf3expiry

Te6edf3ticket Tff7b72= Te6edf3osTff7b72.Td2a8ffurandomTb4b4b4(Te6edf3LXMessageTff7b72.Td2a8ffTICKET_LENGTHTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4[Te6edf3ticketTb4b4b4] Tff7b72= Tb4b4b4[Te6edf3expiresTb4b4b4]

Tff7b72selfTff7b72.Td2a8ffsave_available_ticketsTb4b4b4(Tb4b4b4)

Tff7b72return Tb4b4b4[Te6edf3expiresTb4b4b4, Te6edf3ticketTb4b4b4]

Tff7b72def Td2a8ffremember_ticketTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4, Te6edf3ticket_entryTb4b4b4)Tb4b4b4:

Te6edf3expires Tff7b72= Te6edf3ticket_entryTb4b4b4[T79c0ff0Tb4b4b4]Tff7b72-Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffRemembering ticket for Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3destination_hashTb4b4b4)Tffd700}Ta5d6ff, expires in Tffd700{Te6edf3RNSTff7b72.Td2a8ffprettytimeTb4b4b4(Te6edf3expiresTb4b4b4)Tffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4] Tff7b72= Tb4b4b4[Te6edf3ticket_entryTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4, Te6edf3ticket_entryTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4]

Tff7b72def Td2a8ffget_outbound_ticketTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4:

Te6edf3entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]

Tff7b72if Te6edf3entryTb4b4b4[T79c0ff0Tb4b4b4] Tff7b72> Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3entryTb4b4b4[T79c0ff1Tb4b4b4]

Tff7b72return Tff7b72None

Tff7b72def Td2a8ffget_outbound_ticket_expiryTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4:

Te6edf3entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]

Tff7b72if Te6edf3entryTb4b4b4[T79c0ff0Tb4b4b4] Tff7b72> Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4:

Tff7b72return Te6edf3entryTb4b4b4[T79c0ff0Tb4b4b4]

Tff7b72return Tff7b72None

Tff7b72def Td2a8ffget_inbound_ticketsTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3destination_hashTb4b4b4)Tb4b4b4:

Te6edf3now Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3available_tickets Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72if Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4:

Tff7b72for Te6edf3inbound_ticket Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4:

Tff7b72if Te6edf3now Tff7b72< Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4[Te6edf3inbound_ticketTb4b4b4]Tb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4:

Te6edf3available_ticketsTff7b72.Td2a8ffappendTb4b4b4(Te6edf3inbound_ticketTb4b4b4)

Tff7b72if Tffa657lenTb4b4b4(Te6edf3available_ticketsTb4b4b4) Tff7b72== T79c0ff0Tb4b4b4:

Tff7b72return Tff7b72None

Tff7b72elseTb4b4b4:

Tff7b72return Te6edf3available_tickets

Tff7b72def Td2a8ffclean_throttled_peersTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3expired_entries Tff7b72= Tb4b4b4[Tb4b4b4]

Te6edf3now Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Tff7b72for Te6edf3peer_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffthrottled_peersTb4b4b4:

Tff7b72if Te6edf3now Tff7b72> Tff7b72selfTff7b72.Td2a8ffthrottled_peersTb4b4b4[Te6edf3peer_hashTb4b4b4]Tb4b4b4: Te6edf3expired_entriesTff7b72.Td2a8ffappendTb4b4b4(Te6edf3peer_hashTb4b4b4)

Tff7b72for Te6edf3peer_hash Tff7b72in Te6edf3expired_entriesTb4b4b4: Tff7b72selfTff7b72.Td2a8ffthrottled_peersTff7b72.Td2a8ffpopTb4b4b4(Te6edf3peer_hashTb4b4b4)

Tff7b72def Td2a8ffclean_message_storeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCleaning message storeTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_VERBOSETb4b4b4)

T8b949e# Check and remove expired messages

Te6edf3now Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)

Te6edf3removed_entries Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72for Te6edf3transient_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTff7b72.Td2a8ffcopyTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]

Te6edf3filepath Tff7b72= Te6edf3entryTb4b4b4[T79c0ff1Tb4b4b4]

Te6edf3stamp_value Tff7b72= Te6edf3entryTb4b4b4[T79c0ff6Tb4b4b4]

Te6edf3filename Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffsplitTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]

Te6edf3components Tff7b72= Te6edf3filenameTff7b72.Td2a8ffsplitTb4b4b4(Ta5d6ff"Ta5d6ff_Ta5d6ff"Tb4b4b4)

Tff7b72if Tffa657lenTb4b4b4(Te6edf3componentsTb4b4b4) Tff7b72== T79c0ff3 Tff7b72and Tffa657floatTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4) Tff7b72> T79c0ff0 Tff7b72and Tffa657lenTb4b4b4(Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffsplitTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4)Tb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4) Tff7b72== Tb4b4b4(Te6edf3RNSTff7b72.Td2a8ffIdentityTff7b72.Td2a8ffHASHLENGTHTff7b72/Tff7b72/T79c0ff8Tb4b4b4)Tff7b72*T79c0ff2 Tff7b72and Tffa657intTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff2Tb4b4b4]Tb4b4b4) Tff7b72== Te6edf3stamp_valueTb4b4b4:

Te6edf3timestamp Tff7b72= Tffa657floatTb4b4b4(Te6edf3componentsTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4)

Tff7b72if Te6edf3now Tff7b72> Te6edf3timestampTff7b72+Te6edf3LXMRouterTff7b72.Td2a8ffMESSAGE_EXPIRYTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffPurging message Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3transient_idTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff due to expiryTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_EXTREMETb4b4b4)

Te6edf3removed_entriesTb4b4b4[Te6edf3transient_idTb4b4b4] Tff7b72= Te6edf3filepath

Tff7b72elseTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffPurging message Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3transient_idTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff due to invalid file pathTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_WARNINGTb4b4b4)

Te6edf3removed_entriesTb4b4b4[Te6edf3transient_idTb4b4b4] Tff7b72= Te6edf3filepath

Te6edf3removed_count Tff7b72= T79c0ff0

Tff7b72for Te6edf3transient_id Tff7b72in Te6edf3removed_entriesTb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3filepath Tff7b72= Te6edf3removed_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]

Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTff7b72.Td2a8ffpopTb4b4b4(Te6edf3transient_idTb4b4b4)

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffunlinkTb4b4b4(Te6edf3filepathTb4b4b4)

Te6edf3removed_count Tff7b72+Tff7b72= T79c0ff1

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not remove Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3transient_idTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff from message store. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72if Te6edf3removed_count Tff7b72> T79c0ff0Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCleaned Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3removed_countTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff entries from the message storeTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_VERBOSETb4b4b4)

T8b949e# Check size of message store and cull if needed

Tff7b72tryTb4b4b4:

Te6edf3message_storage_size Tff7b72= Tff7b72selfTff7b72.Td2a8ffmessage_storage_sizeTb4b4b4(Tb4b4b4)

Tff7b72if Te6edf3message_storage_size Tff7b72!= Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ffmessage_storage_limit Tff7b72!= Tff7b72None Tff7b72and Te6edf3message_storage_size Tff7b72> Tff7b72selfTff7b72.Td2a8ffmessage_storage_limitTb4b4b4:

T8b949e# Clean the message storage according to priorities

Te6edf3bytes_needed Tff7b72= Te6edf3message_storage_size Tff7b72- Tff7b72selfTff7b72.Td2a8ffmessage_storage_limit

Te6edf3bytes_cleaned Tff7b72= T79c0ff0

Te6edf3weighted_entries Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3transient_id Tff7b72in Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTff7b72.Td2a8ffcopyTb4b4b4(Tb4b4b4)Tb4b4b4:

Te6edf3weighted_entriesTff7b72.Td2a8ffappendTb4b4b4(Tb4b4b4[

Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4[Te6edf3transient_idTb4b4b4]Tb4b4b4,

Tff7b72selfTff7b72.Td2a8ffget_weightTb4b4b4(Te6edf3transient_idTb4b4b4)Tb4b4b4,

Te6edf3transient_id

Tb4b4b4]Tb4b4b4)

Te6edf3weighted_entriesTff7b72.Td2a8ffsortTb4b4b4(Te6edf3keyTff7b72=Tff7b72lambda Te6edf3weTb4b4b4: Te6edf3weTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4, Te6edf3reverseTff7b72=Tff7b72TrueTb4b4b4)

Te6edf3i Tff7b72= T79c0ff0

Tff7b72while Te6edf3i Tff7b72< Tffa657lenTb4b4b4(Te6edf3weighted_entriesTb4b4b4) Tff7b72and Te6edf3bytes_cleaned Tff7b72< Te6edf3bytes_neededTb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3w Tff7b72= Te6edf3weighted_entriesTb4b4b4[Te6edf3iTb4b4b4]

Te6edf3entry Tff7b72= Te6edf3wTb4b4b4[T79c0ff0Tb4b4b4]

Te6edf3transient_id Tff7b72= Te6edf3wTb4b4b4[T79c0ff2Tb4b4b4]

Te6edf3filepath Tff7b72= Te6edf3entryTb4b4b4[T79c0ff1Tb4b4b4]

Tff7b72if Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisfileTb4b4b4(Te6edf3filepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffunlinkTb4b4b4(Te6edf3filepathTb4b4b4)

Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTff7b72.Td2a8ffpopTb4b4b4(Te6edf3transient_idTb4b4b4)

Te6edf3bytes_cleaned Tff7b72+Tff7b72= Te6edf3entryTb4b4b4[T79c0ff3Tb4b4b4]

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffRemoved Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettyhexrepTb4b4b4(Te6edf3transient_idTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff with weight Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3wTb4b4b4[T79c0ff1Tb4b4b4]Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff to clear up Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Te6edf3entryTb4b4b4[T79c0ff3Tb4b4b4]Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff, now cleaned Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Te6edf3bytes_cleanedTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff out of Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Te6edf3bytes_neededTb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff neededTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_EXTREMETb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffError while cleaning LXMF message from message store. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72finallyTb4b4b4:

Te6edf3i Tff7b72+Tff7b72= T79c0ff1

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffLXMF message store size is now Ta5d6ff"Tff7b72+Te6edf3RNSTff7b72.Td2a8ffprettysizeTb4b4b4(Tff7b72selfTff7b72.Td2a8ffmessage_storage_sizeTb4b4b4(Tb4b4b4)Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff for Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ffpropagation_entriesTb4b4b4)Tb4b4b4)Tff7b72+Ta5d6ff"Ta5d6ff itemsTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_EXTREMETb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not clean the LXMF message store. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72def Td2a8ffsave_locally_delivered_transient_idsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_idsTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)

Tff7b72with Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/local_deliveriesTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwbTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3locally_delivered_fileTb4b4b4:

Te6edf3locally_delivered_fileTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Tff7b72selfTff7b72.Td2a8fflocally_delivered_transient_idsTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not save locally delivered message ID cache to storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72def Td2a8ffsave_locally_processed_transient_idsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72if Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_idsTb4b4b4) Tff7b72> T79c0ff0Tb4b4b4:

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)

Tff7b72with Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/locally_processedTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwbTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3locally_processed_fileTb4b4b4:

Te6edf3locally_processed_fileTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Tff7b72selfTff7b72.Td2a8fflocally_processed_transient_idsTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not save locally processed transient ID cache to storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72def Td2a8ffsave_node_statsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)

Tff7b72with Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/node_statsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwbTa5d6ff"Tb4b4b4) Tff7b72as Te6edf3stats_fileTb4b4b4:

Te6edf3node_stats Tff7b72= Tb4b4b4{

Ta5d6ff"Ta5d6ffclient_propagation_messages_receivedTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_receivedTb4b4b4,

Ta5d6ff"Ta5d6ffclient_propagation_messages_servedTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffclient_propagation_messages_servedTb4b4b4,

Ta5d6ff"Ta5d6ffunpeered_propagation_incomingTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_incomingTb4b4b4,

Ta5d6ff"Ta5d6ffunpeered_propagation_rx_bytesTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffunpeered_propagation_rx_bytesTb4b4b4,

Tb4b4b4}

Te6edf3stats_fileTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Te6edf3node_statsTb4b4b4)Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not save local node stats to storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72def Td2a8ffclean_outbound_stamp_costsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3expired Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4:

Te6edf3entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4[Te6edf3destination_hashTb4b4b4]

Tff7b72if Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72> Te6edf3entryTb4b4b4[T79c0ff0Tb4b4b4] Tff7b72+ Te6edf3LXMRouterTff7b72.Td2a8ffSTAMP_COST_EXPIRYTb4b4b4:

Te6edf3expiredTff7b72.Td2a8ffappendTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72for Te6edf3destination_hash Tff7b72in Te6edf3expiredTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTff7b72.Td2a8ffpopTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffError while cleaning outbound stamp costs. The contained exception was: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fftrace_exceptionTb4b4b4(Te6edf3eTb4b4b4)

Tff7b72def Td2a8ffsave_outbound_stamp_costsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72with Tff7b72selfTff7b72.Td2a8ffcost_file_lockTb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)

Te6edf3outbound_stamp_costs_file Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/outbound_stamp_costsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwbTa5d6ff"Tb4b4b4)

Te6edf3outbound_stamp_costs_fileTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Tff7b72selfTff7b72.Td2a8ffoutbound_stamp_costsTb4b4b4)Tb4b4b4)

Te6edf3outbound_stamp_costs_fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not save outbound stamp costs to storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72def Td2a8ffclean_available_ticketsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

T8b949e# Clean outbound tickets

Te6edf3expired_outbound Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4:

Te6edf3entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]

Tff7b72if Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72> Te6edf3entryTb4b4b4[T79c0ff0Tb4b4b4]Tb4b4b4:

Te6edf3expired_outboundTff7b72.Td2a8ffappendTb4b4b4(Te6edf3destination_hashTb4b4b4)

Tff7b72for Te6edf3destination_hash Tff7b72in Te6edf3expired_outboundTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffoutboundTa5d6ff"Tb4b4b4]Tff7b72.Td2a8ffpopTb4b4b4(Te6edf3destination_hashTb4b4b4)

T8b949e# Clean inbound tickets

Tff7b72for Te6edf3destination_hash Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4:

Te6edf3expired_inbound Tff7b72= Tb4b4b4[Tb4b4b4]

Tff7b72for Te6edf3inbound_ticket Tff7b72in Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4:

Te6edf3entry Tff7b72= Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tb4b4b4[Te6edf3inbound_ticketTb4b4b4]

Te6edf3ticket_expiry Tff7b72= Te6edf3entryTb4b4b4[T79c0ff0Tb4b4b4]

Tff7b72if Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4) Tff7b72> Te6edf3ticket_expiryTff7b72+Te6edf3LXMessageTff7b72.Td2a8ffTICKET_GRACETb4b4b4:

Te6edf3expired_inboundTff7b72.Td2a8ffappendTb4b4b4(Te6edf3inbound_ticketTb4b4b4)

Tff7b72for Te6edf3inbound_ticket Tff7b72in Te6edf3expired_inboundTb4b4b4:

Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4[Ta5d6ff"Ta5d6ffinboundTa5d6ff"Tb4b4b4]Tb4b4b4[Te6edf3destination_hashTb4b4b4]Tff7b72.Td2a8ffpopTb4b4b4(Te6edf3inbound_ticketTb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6fffTa5d6ff"Ta5d6ffError while cleaning available tickets. The contained exception was: Tffd700{Te6edf3eTffd700}Ta5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Te6edf3RNSTff7b72.Td2a8fftrace_exceptionTb4b4b4(Te6edf3eTb4b4b4)

Tff7b72def Td2a8ffsave_available_ticketsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Tff7b72with Tff7b72selfTff7b72.Td2a8ffticket_file_lockTb4b4b4:

Tff7b72tryTb4b4b4:

Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffisdirTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)Tb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTb4b4b4)

Te6edf3available_tickets_file Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstoragepathTff7b72+Ta5d6ff"Ta5d6ff/available_ticketsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffwbTa5d6ff"Tb4b4b4)

Te6edf3available_tickets_fileTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3msgpackTff7b72.Td2a8ffpackbTb4b4b4(Tff7b72selfTff7b72.Td2a8ffavailable_ticketsTb4b4b4)Tb4b4b4)

Te6edf3available_tickets_fileTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149Exception Tff7b72as Te6edf3eTb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffCould not save available tickets to storage. The contained exception was: Ta5d6ff"Tff7b72+Tffa657strTb4b4b4(Te6edf3eTb4b4b4)Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_ERRORTb4b4b4)

Tff7b72def Td2a8ffreload_available_ticketsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:

Te6edf3RNSTff7b72.Td2a8fflogTb4b4b4(Ta5d6ff"Ta5d6ffReloading available tickets from storageTa5d6ff"Tb4b4b4, Te6edf3RNSTff7b72.Td2a8ffLOG_DEBUGTb4b4b4)